package org.workstream.processnode;

import java.util.HashSet;
import java.util.logging.Level;

import org.workstream.data.DataNode;
import org.workstream.driver.LocalDriver;

public abstract class SuperProcessNode extends DataProcessListNode {
	public SuperProcessNode(int pthreadNum,LocalDriver driver){
		super(pthreadNum,driver, null, null);
		produceDataTypeSet = new HashSet<Class<? extends DataNode>>();
		dealDataTypeSet = new HashSet<Class<? extends DataNode>>();
		
	}
	protected void log(Level level,String strMsg){
	}
	public boolean addProduceDataType(Class<? extends DataNode> ctype){
		if(ctype != null)
			return super.getProduceDataTypeSet().add(ctype);
		return false;
	}
	public boolean addDealDataType(Class<? extends DataNode> ctype){
		if(ctype != null)
			return super.getDealDataTypeSet().add(ctype);
		return false;
	}
}
